//package com.talent.core.protocol.mqtt.store;
//
//import com.talent.core.protocol.mqtt.TlMqttSession;
//import com.talent.core.protocol.mqtt.model.entity.TlMessage;
//import com.talent.core.protocol.mqtt.model.entity.TlSubClient;
//import com.talent.core.protocol.mqtt.model.request.TlMqttPublishReq;
//
//import java.util.List;
//
///**
// * @author watson
// * @Description"
// * @date: 2024/12/31 22:12
// */
//public class TlMqttRedisStore implements IMqttStore{
//    @Override
//    public void putSubClient(TlSubClient client) {
//
//    }
//
//    @Override
//    public List<TlSubClient> getSubClientByTopic(String topic) {
//        return null;
//    }
//
//    @Override
//    public List<TlSubClient> getSubClientByTopicAndQos(String topic, int qos) {
//        return null;
//    }
//
//    @Override
//    public void removeSubClientByTopic(String topic, String clientId) {
//
//    }
//
//    @Override
//    public void putSession(String clientId, TlMqttSession session) {
//
//    }
//
//    @Override
//    public TlMqttSession getSessionByClientId(String clientId) {
//        return null;
//    }
//
//    @Override
//    public TlMqttSession removeSessionByClientId(String clientId) {
//        return null;
//    }
//
//    @Override
//    public TlMqttPublishReq getRetainMessageByTopic(String topic) {
//        return null;
//    }
//
//    @Override
//    public TlMessage putRetainMessage(String topic, TlMessage req) {
//        return null;
//    }
//
//    @Override
//    public void brokerStoreMsg(int messageId, TlMqttPublishReq req) {
//
//    }
//
//    @Override
//    public void removeStoreMsg(int messageId) {
//
//    }
//
//    @Override
//    public TlMqttPublishReq getStoreMsg(int messageId) {
//        return null;
//    }
//}
